1f58affc13fab1ecce1fe4d0ebae80c294b7776a,src/main/java/com/metamx/common/guava/LimitedSequence.java,LimitedYielder,next,#OutType#,58

Before Change


    {
      final Yielder<OutType> next = subYielder.next(initValue);
      if (! limitedAccumulator.withinThreshold()) {
        return Yielders.done(next.get(), next);
      }
      return new LimitedYielder<OutType>(LimitedYielder.this, limitedAccumulator);
    }

After Change


    public Yielder<OutType> next(OutType initValue)
    {
      if (!limitedAccumulator.withinThreshold()) {
        return Yielders.done(initValue, subYielder);
      }

      Yielder<OutType> next = subYielder.next(initValue);
      if (!limitedAccumulator.withinThreshold() && (!limitedAccumulator.yielded()
                                                    || limitedAccumulator.isInterruptYield())) {
        next = Yielders.done(next.get(), next);
      }
      return new LimitedYielder<OutType>(next, limitedAccumulator);
    }